package com.mq.common.Arguments;
import java.io.Serializable;
public class BasicConsumeArguments extends BasicArguments implements Serializable {
    private String consumeTag;
    private String queueName;
    private boolean autoAck;
    //这个类对应的 basicConsume 方法中还有一个参数是回调函数（如何处理消息）
    //这个回调函数，是不能通过网络传输
    //站在 broker serner 这边，针对消息的处理回调，是统一的，就是直接那消息给客户端
    //客户端这边收到消息之后，再在客户端自己这端执行一个用户自定义的回调就行
    //客户端不需要把自己要执行的回调告诉服务器
    //这个类不需要 comsumer 成员

    public String getConsumeTag() {
        return consumeTag;
    }

    public void setConsumeTag(String consumeTag) {
        this.consumeTag = consumeTag;
    }

    public String getQueueName() {
        return queueName;
    }

    public void setQueueName(String queueName) {
        this.queueName = queueName;
    }

    public boolean isAutoAck() {
        return autoAck;
    }

    public void setAutoAck(boolean autoAck) {
        this.autoAck = autoAck;
    }
}